const fs = require('fs')
const es = require('event-stream')

fs.createReadStream('out.log.txt')
  .pipe(es.split())
  .pipe(es.map(function (line, cb) {
    console.log(line)
    console.log(typeof line)
    line += '>>>'
    cb(null, line)
  }))
  .pipe(fs.createWriteStream('out.split.txt'))
